package com.ibm.cps.kafka;

import com.ibm.cps.message.MessageFactory.MessageType;

public interface KafkaTopicConstructor {
	 public String getMessageTopic(String tenantid);
	 public String getMessageCountTopic(String tenantid);
	 public String getMetadataAddTopic(String tenantid);
	 public String getMetadataDeleteTopic(String tenantid) ;
	 public String getDataSourceDeleteTopic(String tenantid);
	 public String getDataSourceAddTopic(String tenantid);
}
